package com.fafu.mq.common.arguments;

import lombok.Data;

import java.io.Serializable;
@Data
public class BasicConsumeArguments extends BasicArguments implements Serializable {
    private String consumerTag;
    private String queueName;
    private boolean autoAck;
    // 这个类对应的方法中, 有一个参数是回调函数 (如何来进行处理)
    // 这个回调函数, 是不能通过网络进行传输的
    // 站在 broker server 这边, 针对消息的处理回调, 是同统一的处理 (把消息返回给客户端)
    // 客户端这边收到消息之后, 再在客户端这边执行一个用户自定义的回调就行
    // 此时, 客户端也不需要把自己的回调告诉服务器
    // 这个类就不需要 consumer 这个成员了
}
